package com.bossien.flink.handler.exam;


import com.bossien.flink.annatation.JHandler;
import com.bossien.flink.factory.ExcutionFactory;
import com.bossien.flink.handler.exam.handler.ExamDataStreamExecute;
import com.bossien.flink.handler.exam.handler.ExamStreamBySqlExecute;
import com.bossien.flink.interfaces.IExamHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;

/**
 * @author 胡春林
 * 统计总分 全国排名 窗口模式
 */
@Slf4j
@JHandler(value = "考试作业")
public class CalculationExamHandler implements IExamHandler {

    @Autowired
    ExcutionFactory excutionFactory;

    @Override
    public Boolean handler(){
      return  excutionFactory.getRabbitInstance(ExamStreamBySqlExecute.class,true);}
}
